package com.solar.etl.concurrent;

import java.util.concurrent.atomic.AtomicInteger;



public interface Callable<E,T> {
	public void init(E mapping,AtomicInteger rows,AtomicInteger skipped,EtlThreadPool pool);
	public void execute(T item);
	public void errorCallBack();
	public void finish();
}
